package org.jeecg.modules.iot.mqtt.server;

import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;
import javax.annotation.PreDestroy;

@Slf4j
@Component
public class MqttStartServer {


    @PostConstruct
    public void start() throws InterruptedException {
     //   String[] topicSend= {"/device/send","/iot/recv"};
     //  clientMQTT.clientStart(topicSend,"/device/send","close");
     //  log.info("启动完成");
      /*  String topic="/device/send";
        String sendMessage="333";

            this.mqttSendClient.publish(false, topic, sendMessage);
        System.out.println("topic:" + topic + "\nmessage:" + sendMessage);*/


    }
    @PreDestroy
    public void destroy() {

    }
}
